/*******************************************************************************
 * Copyright (c) 2022, 2022
 ******************************************************************************/
package com.alex.demo.kafka.controller;

import org.springframework.kafka.annotation.KafkaListener;
import org.springframework.stereotype.Component;

/**
 * @Version 1.0
 * @Author Alex
 * @Created Dec 2022/9/20 15:21
 * @Description
 *              <p>
 */
@Component
public class KafkaConsumer {

	@KafkaListener(topics = "topic")
	public void consumer(String msg) {
		System.out.println("收到消息: " + msg);
	}

}
